package org.ruizhijie.i.impl;

import org.ruizhijie.config.TopicQueue;
import org.ruizhijie.i.IPublisher;


public class InPortPublisherImpl implements IPublisher {
	
	private TopicQueue tq;
	
	public InPortPublisherImpl(TopicQueue tq){
		this.tq = tq;
	}
	
	
	@Override
	public void publish(String topic, byte[] msg) {
		tq.update(topic, msg);
	}

}
